google.golang.org/grpc.clientStream.callInfo (field)
15 uses
google.golang.org/grpc (current package)
stream.go#L359: callInfo: callInfo,
stream.go#L447: ctx := newContextWithRPCInfo(cs.ctx, cs.callInfo.failFast, cs.callInfo.codec, cs.compressorV0, cs.compressorV1)
stream.go#L454: FullMethodName: method, FailFast: cs.callInfo.failFast,
stream.go#L460: FailFast: cs.callInfo.failFast,
stream.go#L504: pick, err := cs.cc.pickerWrapper.pick(a.ctx, cs.callInfo.failFast, pickInfo)
stream.go#L546: if cs.callInfo.authority == "" {
stream.go#L577: callInfo *callInfo
stream.go#L931: if cs.replayBufferSize > cs.callInfo.maxRetryRPCBufferSize {
stream.go#L975: if payloadLen > *cs.callInfo.maxSendMessageSize {
stream.go#L976: return status.Errorf(codes.ResourceExhausted, "trying to send message larger than max (%d vs. %d)", payloadLen, *cs.callInfo.maxSendMessageSize)
stream.go#L1086: o.after(cs.callInfo, cs.attempt)
stream.go#L1164: if !acceptedCompressorAllows(cs.callInfo.acceptedResponseCompressors, ct) {
stream.go#L1174: if err := recv(&a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, payInfo, a.decompressorV1, false); err != nil {
stream.go#L1212: if err := recv(&a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, nil, a.decompressorV1, false); err == io.EOF {